#pragma once

#include "stream/KvReader.h"

namespace stream {

class SequenceReader : public KvReader<size_t, std::shared_ptr<std::string>> {
public:
    typedef size_t key_type;
    typedef std::shared_ptr<std::string> value_type;
    typedef std::pair<key_type, value_type> record_type;


    SequenceReader(std::shared_ptr<Topic> topic) ;
	~SequenceReader() override;

};
SequenceReader * makeSequenceReaderMock(std::shared_ptr<Topic> topic, size_t offset);
SequenceReader * makeSequenceReader(std::shared_ptr<Topic> topic, size_t offset);

}//end namespace stream
